package studio.raptor.ddal.core.log.queue;

import java.util.Map;

/**
 * JavaQueue 队列操作接口
 */
public interface IQueueHelper {

	/**
	 * 把日志对象写入队列
	 * @param obj
	 * @throws Exception
	 */
	void writeObj(Object obj, String logType);

	/**
	 * 从日志队列中读取消息
	 * @return
	 * @throws Exception
	 */
	Object readObj(String logType);

	/**
	 * 获取队列深度
	 * @return
	 * @throws Exception
	 */
	int getDepth(String logType);

	/**
	 * 获取队列Map
	 * @return
	 */
	Map getJavaQueueMap();
}
